package com.example.sender;

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.stereotype.Component;

@Component
public class ProviderSender implements ApplicationRunner {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    @Override
    public void run(ApplicationArguments args) throws Exception {
//        rabbitTemplate.convertAndSend("up_queue", "message:"+1+">>>>test"+1);

//        Thread thread=new Thread(new Runnable() {
//            @Override
//            public void run() {
//                int j=0;
//                while (true){
//                    for (int i = 0; i < 2; i++) {
//                        rabbitTemplate.convertAndSend("test_1", "message:"+j+">>>>test"+i);
//                    }
//                    j++;
//                    try {
//                        Thread.sleep(1000);
//                    } catch (InterruptedException e) {
//                        e.printStackTrace();
//                    }
//                }
//            }
//        });
//        thread.start();
//
//        Thread thread1=new Thread(new Runnable() {
//            @Override
//            public void run() {
//                int j=0;
//                while (true){
//                    for (int i = 0; i < 2; i++) {
//                        rabbitTemplate.convertAndSend("test_2", "message:"+j*10000+">>>>test"+i*20);
//                    }
//                    j++;
//                    try {
//                        Thread.sleep(1000);
//                    } catch (InterruptedException e) {
//                        e.printStackTrace();
//                    }
//                }
//            }
//        });
//        thread1.start();
    }
}
